const express = require('express');
const router = express.Router();
const pool = require('../pool.js');
// 接口类型：用户注册
// 接口地址：http://127.0.0.1:3000/v1/users/reg
// 请求方式：POST
router.post('/reg',(req,res,next)=>{
    var obj=req.body;
    pool.query('insert into hsb_user values(null,?,?)',[obj.phone,obj.upwd],(err,result)=>{
        if(err){
            next(err);
            return;
        }
        if(result.affectedRows>0){
            res.send({code:200,msg:'注册成功'});
        }else{
            res.send({code:400,msg:'注册失败'});
        }
    })
})
// 接口类型：手机号验证
// 接口地址：http://127.0.0.1:3000/v1/users/exists
// 请求方式：GET
router.get('/exists',(req,res,next)=>{
    var obj=req.query;
    pool.query('select * from hsb_user where phone=?',[obj.phone],(err,result)=>{
        if(err){
            next(err);
            return;
        }
        if(result.length>0){
            res.send({code:200,msg:'手机号已存在'});
        }else{
            res.send({code:400,msg:'手机号可用'});
        }
    })
})
// 接口类型：用户登录
// 接口地址：http://127.0.0.1:3000/v1/users/login
// 请求方式：post
router.post('/login',(req,res,next)=>{
    var obj=req.body;
    pool.query('select * from hsb_user where phone=? and upwd=?',[obj.phone,obj.upwd],(err,result)=>{
        if(err){
            next(err);
            return;
        }
        if(result.length>0){
            res.send({code:200,msg:'登录成功'});
        }else{
            res.send({code:400,msg:'登录失败'});
        }
    })
})
// 接口类型：用户查询
// 接口地址：http://127.0.0.1:3000/v1/users/list
// 请求方式：get
 router.get('/list',(req,res,next)=>{
    var obj=req.query
    pool.query('select uid from hsb_user where phone=?',[obj.phone],(err,result)=>{
        if(err){
            next(err)
            return
        }
        if(result.length>0){
            res.send({code:200,msg:'查询成功',result})
        }else{
            res.send({code:400,msg:'查询失败'})
        }
    })
})
// 接口类型：用户删除
// 接口地址：http://127.0.0.1:3000/v1/users/deluser
// 请求方式：delete
/* router.delete('/deluser/:id',(req,res,next)=>{
    var obj=req.params
    pool.query('delete from userlogin where id=?',[obj.id],(err,result)=>{
        if(err){
            next(err)
            return
        }
        if(result.affectedRows>0){
            res.send({code:200,msg:'删除成功'})
        }else{
            res.send({code:400,msg:'删除失败'})
        }
    })
})
*/
// 接口类型：用户更新
// 接口地址：http://127.0.0.1:3000/v1/users/update
// 请求方式：put
router.put('/update',(req,res,next)=>{
    var obj=req.body
    pool.query('update hsb_user set phone=?,upwd=? where uid=?',[obj.phone,obj.upwd,obj.uid],(err,result)=>{
        if(err){
            next(err)
            return
        }
        if(result.affectedRows>0){
            res.send({code:200,msg:'修改成功'})
        }else{
            res.send({code:400,msg:'修改失败'})
        }
    })
})

// 接口类型：用户评价
// 接口地址：http://127.0.0.1:3000/v1/users/appraise
// 请求方式：get
router.get('/appraise',(req,res,next)=>{
    pool.query('select * from hsb_appraise',(err,result)=>{
        if(err){
            next(err)
            return
        }
        if(result.length>0){
            res.send({code:200,msg:'suc',result})
        }else{
            res.send({code:400,msg:'faile'})
        }
    })
})


// 接口类型：增加用户地址信息
// 接口地址：http://127.0.0.1:3000/v1/users/insertAddress
// 请求方式：post
router.post('/insertAddress',(req,res,next)=>{
    var obj = req.body;
    let sql="insert into hsb_address values(null,?,?,?,?,?,?,?,?,?)"
    pool.query(sql,[obj.uid,obj.name,obj.phone,obj.province,obj.city,obj.county,obj.address,obj.date,obj.Rmethod],(err,result)=>{
        if(err){
            next(err);
            return;
        }
        if(result.affectedRows>0){
            res.send({code:200,msg:'添加成功'});
        }else{
            res.send({code:400,msg:'添加失败'});
        }
    })
})


// 接口类型：获取用户地址信息
// 接口地址：http://127.0.0.1:3000/v1/users/getAddress
// 请求方式：get
router.get('/getAddress',(req,res,next)=>{
    var obj = req.query;
    let sql="select * from  hsb_address where user_id=?"
    pool.query(sql,[obj.uid],(err,result)=>{
        if(err){
            next(err);
            return;
        }
        if(result.length>0){
            res.send({code:200,msg:'suc',result});
        }else{
            res.send({code:400,msg:'fail'});
        }
    })
})





module.exports = router;